package com.atguigu.gmall.activity.redis;

import org.springframework.stereotype.Component;

import java.util.HashMap;

/**
 * 当监听器监听到Redis服务器中消息的时候,对消息是如何处理 就在当前类中写具体操作
 * 该类用于每个微服务接收Redis发送的状态位
 */
@Component
public class MessageReceive {
    //处理消息的方法
    public void receiveMessage(String message) {
        //message :  "skuId:1"   "skuId:0"
        System.out.println("Redis监听器中接收到的消息是:" + message);
        //去掉 " 注意转义
        message = message.replaceAll("\"", "");
        //切割
        String[] msg = message.split(":");
        //放入本地缓存
        CacheHelper.put(msg[0], msg[1]);
    }
}
